package com.hr.reactive.flux;

import com.google.common.collect.Lists;
import com.hr.reactive.common.Utils;
import reactor.core.publisher.Flux;

/**
 * 延迟执行
 * @author Administrator
 */
public class Lec06FluxDefer {
    public static void main(String[] args) {
       Flux.defer(()->Flux.fromIterable(Lists.newArrayList())).subscribe(Utils.subscriber());
    }
}
